package com.hq.kafka;
/**
 *  清分系统记账后数据返回表
 *  @KafkaListener(id = "batchWithPartition",clientIdPrefix = "bwp",containerFactory = "batchContainerFactory",
 *                      topicPartitions = {
 *                         @TopicPartition(topic = "topics.quick.batch.partition",partitions = {"1","3"}),
 *                         @TopicPartition(topic = "topics.quick.batch.partition",partitionOffsets = @PartitionOffset(partition = "2",initialOffset = "100"))
 *                      }
 *                  )
 *            @Header(KafkaHeaders.RECEIVED_MESSAGE_KEY) Integer key,
 *             @Header(KafkaHeaders.RECEIVED_PARTITION_ID) int partition,
 *             @Header(KafkaHeaders.RECEIVED_TOPIC) String topics,
 *             @Header(KafkaHeaders.RECEIVED_TIMESTAMP) long ts
 * @author hq
 */

/**
 *
 * 主题定义
 * 湖南出口站其他交易流水表							tb_laneexlist				TRC_LANEEXLIST
 * 站合计数表										tb_lanesummation			TB_LANESUMMATION
 * 站合计数流水汇总列表								tb_lanesummation_summary	TB_LANESUMMATION_SUMMARY
 * 站合计数推送作废表								tb_lanesummation_del		TB_LANESUMMATION_DEL
 * 清算交易详细表									ct_clear					CT_DETAILS
 * 清算交易汇总表									ct_clear_sum				CT_CLEAR_SUM
 * 系统外收入表										tb_outsideincome			TB_OUTSIDEINCOME
 * 系统外收入推送作废表								tb_outsideincome_del		TB_OUTSIDEINCOME_DEL
 * 2.3.6ETC 拆分结果（以通行省门架汇总记录拆）下载	transaction_etcpasstd_json	TRANSACTION_ETCPASSTD_JSON
 * 2.3.7ETC 拆分结果（以出口交易正常记账拆分）下载	etcts_exitptsd_json			ETCTS_EXITPTSD_JSON
 * 2.3.8ETC 拆分结果（以出口交易争议记账拆分）下载	etcts_passdd_json			ETCTS_PASSDD_JSON
 * 机场高速出口站 ETC 通行数据表（TB_EXETCPU_HN）	jcgs_exetcpu				JCGS_EXETCPU
 * 清分系统记账后数据返回表	 						ct_clear_aftercharge		CT_CLEAR_AFTERCHARGE
 * @author hq
 */
@SuppressWarnings("all")
public interface Topic {
    String TRC_LANEEXLIST = "TRC_LANEEXLIST";

    String CT_DETAILS = "CT_DETAILS";
    String CT_CLEAR_SUM = "CT_CLEAR_SUM";
    String CT_CLEAR_AFTERCHARGE = "CT_CLEAR_AFTERCHARGE";

    String TB_OUTSIDEINCOME = "TB_OUTSIDEINCOME";
    String TB_OUTSIDEINCOME_DEL = "TB_OUTSIDEINCOME_DEL";
    String TB_LANESUMMATION = "TB_LANESUMMATION";
    String TB_LANESUMMATION_SUMMARY = "TB_LANESUMMATION_SUMMARY";
    String TB_LANESUMMATION_DEL = "TB_LANESUMMATION_DEL";

    String TRANSACTION_ETCPASSTD_JSON = "TRANSACTION_ETCPASSTD_JSON";

    String ETCTS_EXITPTSD_JSON = "ETCTS_EXITPTSD_JSON";
    String ETCTS_PASSDD_JSON = "ETCTS_PASSDD_JSON";

    String JCGS_EXETCPU = "JCGS_EXETCPU";
    String HB_SMS = "HB_SMS";
}
